package my.yuan.ms.rediskafkams.config;

import my.yuan.ms.rediskafkams.controller.vo.MsVO;
import my.yuan.ms.rediskafkams.utils.ProtostuffUtil;
import org.apache.kafka.common.serialization.Deserializer;

/**
 * @author zzMh
 * @Description TODO
 */
public class MsVoKafkaDeserializer implements Deserializer<MsVO> {

    @Override
    public MsVO deserialize(String s, byte[] bytes) {
        return ProtostuffUtil.deserializer(bytes, MsVO.class);
    }
}
